title: 3.窗口触发器
date: 2020-03-20 11:55:57
banner:
tags:
categories:
- 需要指定Time Notion. Apache Flink：使用EventTime与WaterMark进行流数据处理
状态编程
由于同样引入了时间，我们可以想到，最简单的方法其实与之前的热门统计类似，只需要按照用户ID分流，然后遇到登录失败的事件时将其保存在ListState中，然后设置一个定时器，2秒后触发。定时器触发时检查状态中的登录失败事件个数，如果大于等于2，那么就输出报警信息。
CEP
- 定义匹配模式
- 在数据流中匹配出定义好的模式
1小时内一个ip下的用户数
- 一分钟内一个ip下的用户数